package com.gientech.spring.mq;

import org.springframework.cloud.stream.annotation.Input;
import org.springframework.messaging.SubscribableChannel;

public interface MessageSink {
    String MESSAGE_INPUT = "message_input";

    @Input(MessageSink.MESSAGE_INPUT)
    SubscribableChannel input();
}
